package com.asinking.sink;

import com.asinking.debezium.DebeziumObject;
import org.apache.flink.connector.jdbc.JdbcStatementBuilder;

import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.util.Collection;

public class CkSinkBuilder implements JdbcStatementBuilder<DebeziumObject> {


    @Override
    public void accept(PreparedStatement preparedStatement, DebeziumObject debeziumObject) throws SQLException {





    }
}
